package com.xbongbong.pro.rabbitmq.binders;

import com.xbongbong.pro.rabbitmq.constant.BusinessBinderConstant;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.stereotype.Service;

/**
 * @author 吴峰
 * @version v1.0
 * @date 2019/5/7 14:50
 * @since v1.0
 */
@Service("businessRuleBinder")
public interface BusinessRuleBinder {

    /**
     * 业务规则生产者
     * @return
     */
    @Output(BusinessBinderConstant.RULE_OUTPUT)
    MessageChannel ruleOutput();


    /**
     * 导出触发业务规则生产者
     * @return
     */
    @Output(BusinessBinderConstant.IMPORT_RULE_OUTPUT)
    MessageChannel importRuleOutput();
}
